e904c3fb44db4bee942c4290e76ad4745fd172de,fabric/fabric-core/src/main/java/io/fabric8/internal/ZooKeeperClusterServiceImpl.java,ZooKeeperClusterServiceImpl,createCluster,#List#CreateEnsembleOptions#,147

Before Change



                // configure this server in the ensemble
                String ensembleMemberProfile = profileRegistry.get().getProfile(version, "fabric-ensemble-" + newClusterId + "-" + Integer.toString(index), true);
                profileRegistry.get().setProfileAttribute(version, ensembleMemberProfile, "hidden", "true");
                profileRegistry.get().setProfileAttribute(version, ensembleMemberProfile, "parents", ensembleProfile);

                String port1 = Integer.toString(findPort(usedPorts, ip, mapPortToRange(Ports.DEFAULT_ZOOKEEPER_SERVER_PORT, minimumPort, maximumPort)));

After Change


            IllegalStateAssertion.assertFalse(profileRegistry.get().hasProfile(versionId, profileId), "Profile already exists: " + versionId + "/" + profileId);
            String ensembleProfileId = profileRegistry.get().getProfile(versionId, profileId, true);
            profileRegistry.get().setProfileAttribute(versionId, ensembleProfileId, "abstract", "true");
            profileRegistry.get().setProfileAttribute(versionId, ensembleProfileId, "hidden", "true");

            Properties ensembleProperties = new Properties();
            ensembleProperties.put("tickTime", String.valueOf(options.getZooKeeperServerTickTime()));
            ensembleProperties.put("initLimit", String.valueOf(options.getZooKeeperServerInitLimit()));
            ensembleProperties.put("syncLimit", String.valueOf(options.getZooKeeperServerSyncLimit()));
            ensembleProperties.put("dataDir", options.getZooKeeperServerDataDir() + File.separator + newClusterId);

            int index = 1;
            String connectionUrl = "";
            String realConnectionUrl = "";
            String containerList = "";
            for (String container : containers) {
                String ip = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_IP.getPath(container));

                String minimumPort = String.valueOf(Ports.MIN_PORT_NUMBER);
                String maximumPort = String.valueOf(Ports.MAX_PORT_NUMBER);
                String bindAddress = "0.0.0.0";

                if (exists(curator.get(), ZkPath.CONTAINER_PORT_MIN.getPath(container)) != null) {
                    minimumPort = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_PORT_MIN.getPath(container));
                }

                if (exists(curator.get(), ZkPath.CONTAINER_PORT_MAX.getPath(container)) != null) {
                    maximumPort = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_PORT_MAX.getPath(container));
                }

                if (exists(curator.get(), ZkPath.CONTAINER_BINDADDRESS.getPath(container)) != null) {
                    bindAddress = getSubstitutedPath(curator.get(), ZkPath.CONTAINER_BINDADDRESS.getPath(container));
                }

                String ensembleMemberConfigName = "io.fabric8.zookeeper.server-" + newClusterId + ".properties";
                Properties ensembleMemberProperties = new Properties();

                // configure this server in the ensemble
                profileId = "fabric-ensemble-" + newClusterId + "-" + index;
                IllegalStateAssertion.assertFalse(profileRegistry.get().hasProfile(versionId, profileId), "Profile already exists: " + versionId + "/" + profileId);
                String ensembleMemberProfileId = profileRegistry.get().getProfile(versionId, profileId, true);
                profileRegistry.get().setProfileAttribute(versionId, ensembleMemberProfileId, "hidden", "true");
                profileRegistry.get().setProfileAttribute(versionId, ensembleMemberProfileId, "parents", ensembleProfileId);